package com.coderknock.jedis.push;

import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;

public class TestPublish {
    @Test
    public void test() throws InterruptedException {
        Jedis jedis = JedisFactory.getJedis();
        jedis.publish("redisChatTest", "我是天才");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "我牛逼");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "哈哈");
    }
}
